package dim.app;


import com.bw.gmall.realtime.common.bean.BaseApp;
import com.bw.gmall.realtime.common.constant.Constant;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * 处理维度数据
 */
public class DimApp extends BaseApp {
    public static void main(String[] args) throws Exception {
//        new DimApp().start(10001,4, "dim_app",Constant.TOPIC_DB);
    }
    @Override
    public void handle(StreamExecutionEnvironment streamExecutionEnvironment, DataStreamSource<String> dataStreamSource) {
        dataStreamSource.print();
        /**
         * 把维度放到HBase
         */
    }
}
